import org.apache.hadoop.conf.Configuration
import org.apache.hadoop.mapreduce.Job
import org.apache.hadoop.util.GenericOptionsParser
import org.junit.Test

class MapReduceTest {
  @Test
  fun test() {
    val conf = Configuration()
    conf.set("fs.defaultFS", "hdfs://192.168.244.143:9000")
    System.setProperty("HADOOP_USER_NAME", "root")
    val job = Job.getInstance(conf, "My Word Count")
    val otherArgs = GenericOptionsParser(conf, emptyArray()).remainingArgs
    if (otherArgs.size < 2) {

    }
  }
}